﻿using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using test.kafka;

namespace kafka.unit_test
{
    class Program
    {
        static void Main(string[] args)
        {
            ProducerConfig producerConfig = new ProducerConfig
            {
                KafkaServer = "121.199.64.205:19092",
                Topic = "liuzw_test"
            };
            KafkaProducer producer = new KafkaProducer(producerConfig);
            producer.Send("hello").GetAwaiter().GetResult();
        }
    }
}
